package main

import (
	"fmt"
	"net"
	"time"

	"gitee.com/zhaoqinghuan/rpc/transport"
)

func main() {
	conn, err := net.DialTimeout("udp", "127.0.0.1:5678", 30*time.Minute) // 尝试建立一个到地址 127.0.0.1:5678 的 UDP 连接，超时时间为 30 分钟。
	transport.CheckError(err)
	defer conn.Close() // 延迟执行 conn.Close()，在当前函数返回之前关闭连接

	for i := 0; i < 3; i++ {
		requestBytes := []byte("china") // 将字符串 "china" 转换为字节切片 []byte，并赋值给变量 requestBytes。在 UDP 通信中，数据通常以字节切片的形式发送。
		// UDP 不需要拼接分隔符
		_, err = conn.Write(requestBytes) // 通过连接 conn 发送 requestBytes 数据
		transport.CheckError(err)
		fmt.Printf("write request %s\n", string(requestBytes))
	}
}
